//package com.game.cluster;
//
//
//import com.game.config.NodeConfig;
//import com.game.curator.MarsNode;
//import com.game.net.Connect;
//import com.game.netty.ConnectPool;
//
//public class ClusterClient {
//    public NodeConfig nodeConfig;
//
//    public MarsNode marsNode;
//
//    public ConnectPool connectPool;
//
//    private ClusterSystem clusterSystem;
//
//    public ClusterClient(MarsNode marsNode, ClusterSystem clusterSystem) {
//        this.clusterSystem = clusterSystem;
//        init(marsNode);
//    }
//
//    public void init(MarsNode marsNode) {
//        this.marsNode = marsNode;
//        this.nodeConfig = marsNode.getNodeConfig();
//        this.connectPool = this.clusterSystem.getMarsConnectPool(this.nodeConfig.getTcpAddress());
//    }
//
//    public Connect getConnect() throws InterruptedException {
//        return (Connect)this.connectPool.getConnect();
//    }
//
//    public Connect getConnectSync() throws InterruptedException {
//        return (Connect)this.connectPool.getConnectSync();
//    }
//
//    public void write(Object msg) throws InterruptedException {
//        this.connectPool.getConnect().write(msg);
//    }
//
//    public boolean canReceive(int messageType) {
//        if (this.marsNode != null && this.marsNode.getNodeConfig() != null && this.marsNode.getNodeConfig().getMicserviceMessageTypes() != null)
//            return this.marsNode.getNodeConfig().getMicserviceMessageTypes().contains(Integer.valueOf(messageType));
//        return false;
//    }
//
//    public String getType() {
//        return this.nodeConfig.getType();
//    }
//
//    public void close(Connect connect) {
//        this.connectPool.close(connect);
//        if (connect != null)
//            connect.close();
//    }
//
//    public void shutdown() {
//        if (this.connectPool != null)
//            this.connectPool.shutdown();
//    }
//}
